﻿using Confluent.Kafka;
using KafkaService;
using System;
using System.Collections.Generic;
using System.Threading.Tasks;

namespace KafkaConsumer
{
    class Program
    {
       async static Task Main(string[] args)
        {
            Console.WriteLine("Hello World!");

            IKafkaService kafkaService = new KafkaService.Implements.KafkaService();
            var topcis = new List<string>() { "test-topic" };
            await kafkaService.SubscribeAsync<dynamic>(topcis, result =>
            {
                Console.WriteLine(result);
            });
            Console.ReadLine();
        }
    }
}
